package com.crawler.db

import com.crawler.message.TaskParamMessage

/**
  * Created by tongtao.zhu on 2016/12/1.
  */
trait CrawlerDataPersistence {
  def persist(taskParam: TaskParamMessage, content: String)
}

class CrawlerDataPersistenceLocal extends CrawlerDataPersistence{
  override def persist(taskParam: TaskParamMessage, content: String) = {

  }
}

class CrawlerDataPersistenceHive extends CrawlerDataPersistence{
  override def persist(taskParam: TaskParamMessage, content: String) = {

  }
}
